package day02

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

/**
  * 通过点击流日志分析pv
  */
object PV {
  def main(args: Array[String]): Unit = {
    //初始化
    val sparkConf: SparkConf = new SparkConf().setAppName("PV").setMaster("local[2]")
    val sc: SparkContext = new SparkContext(sparkConf)
    sc.setLogLevel("WARN")
    //加载文件
    val data: RDD[String] = sc.textFile("file:///F:\\weblog\\output\\log\\part-m-00000")
    //统计文件中有多少行记录
    val result: Long = data.count()
    //打印计算结果
    println(result)
    //释放资源
    sc.stop()
  }
}
